package com.example.test;


public class KafkaProducerABCDEFGHIJExample {


    public static void main(String[] args) throws Exception {
        new Thread(()->{
            com.example.test.stream1.KafkaStreamAllJoinExample.main(null);
        }).start();
        new Thread(()->{
            com.example.test.stream2.KafkaStreamAllJoinExample.main(null);
        }).start();
        new Thread(()->{
            com.example.test.stream3.KafkaStreamAllJoinExample.main(null);
        }).start();
        new Thread(()->{
            com.example.test.stream4.KafkaStreamAllJoinExample.main(null);
        }).start();
        new Thread(()->{
            com.example.test.stream5.KafkaStreamAllJoinExample.main(null);
        }).start();
        new Thread(()->{
            com.example.test.stream6.KafkaStreamAllJoinExample.main(null);
        }).start();
        new Thread(()->{
            com.example.test.stream7.KafkaStreamAllJoinExample.main(null);
        }).start();
        new Thread(()->{
            com.example.test.stream8.KafkaStreamAllJoinExample.main(null);
        }).start();
        new Thread(()->{
            com.example.test.stream9.KafkaStreamAllJoinExample.main(null);
        }).start();
        new Thread(()->{
            com.example.test.stream10.KafkaStreamAllJoinExample.main(null);
        }).start();
        com.example.test.stream11.KafkaStreamAllJoinExample.main(null);
        com.example.test.stream12.KafkaStreamAllJoinExample.main(null);
        com.example.test.stream13.KafkaStreamAllJoinExample.main(null);
        com.example.test.stream14.KafkaStreamAllJoinExample.main(null);
        com.example.test.stream15.KafkaStreamAllJoinExample.main(null);
        com.example.test.stream16.KafkaStreamAllJoinExample.main(null);
        com.example.test.stream17.KafkaStreamAllJoinExample.main(null);
        com.example.test.stream18.KafkaStreamAllJoinExample.main(null);
        com.example.test.stream19.KafkaStreamAllJoinExample.main(null);
        com.example.test.stream20.KafkaStreamAllJoinExample.main(null);
        Thread.currentThread().join();

    }

}